package org.decomposer.contrib.hadoop.phrases;

import java.io.IOException;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;
import org.decomposer.contrib.hadoop.job.PhraseExtractorJob.PhrazerCounterTypes;


public class IntSumReducer extends Reducer<Text, IntWritable, Text, IntWritable>
{
  private IntWritable result = new IntWritable();

  public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException
  {
    int sum = 0;
    for (IntWritable val : values)
    {
      sum += val.get();
    }
    result.set(sum);
    context.write(key, result);
    context.getCounter(PhrazerCounterTypes.NUM_REDUCER_VALUES).increment(1);
  }
}